package mq

import (
	amqp "github.com/rabbitmq/amqp091-go"
	"zhongxc.cc/go-common/errs"
)

func NewRabbitMqConnection() *amqp.Connection {
	// 1. 尝试连接RabbitMQ，建立连接
	// 该连接抽象了套接字连接，并为我们处理协议版本协商和认证等。
	conn, err := amqp.Dial("amqp://admin:123@192.168.98.128:5672/")
	errs.FailOnError(err, "Failed to connect to RabbitMQ")
	return conn
}
